package com.fanxuankai.boot.confluent.service;

import com.fanxuankai.boot.confluent.dto.KsqldbObjectDTO;
import com.fanxuankai.boot.confluent.dto.KsqldbObjectDropDTO;

/**
 * @author fanxuankai
 */
public interface KsqldbObjectService {
    /**
     * 创建
     *
     * @param dto /
     * @throws Exception /
     */
    void create(KsqldbObjectDTO dto) throws Exception;

    /**
     * 删除
     *
     * @param dto /
     * @throws Exception /
     */
    void drop(KsqldbObjectDropDTO dto) throws Exception;
}
